﻿using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using Viettel.VOFFICE.DAO.Models;

namespace Viettel.VOFFICE.DAO.DAL.Repository
{
    /// <summary>
    /// xử lý quan hệ giữa user và node của luồng
    /// </summary>
    public class NodeUserRepository : IRepository<NodeUser>
    {
        private VOFFICEContext context;
        public NodeUserRepository(VOFFICEContext context)
        {
            if (context == null)
            {
                throw new Exception("Context must be init");
            }
            this.context = context;
        }
        public IEnumerable<NodeUser> Get()
        {
            throw new NotImplementedException();
        }

        public NodeUser GetById(object id)
        {
            throw new NotImplementedException();
        }

        public NodeUser GetByBothId(int nodeId, Guid userId)
        {
            return context.NodeUsers.FirstOrDefault(o => o.NodeId == nodeId && o.UserId == userId);
        }

        public IEnumerable<NodeUser> FindByName(object s)
        {
            throw new NotImplementedException();
        }

        public void Insert(NodeUser T)
        {
            if (null != T)
            {
                if (GetByBothId(T.NodeId, T.UserId) == null)
                {
                    context.NodeUsers.Add(T);
                    Save();
                }
                else
                {
                    Update(T);
                }
            }
        }

        public void Delete(object id)
        {
            throw new NotImplementedException();
        }

        public void Delete(NodeUser T)
        {
            throw new NotImplementedException();
        }

        public void Update(NodeUser T)
        {
            context.Entry(T).State = EntityState.Modified;
            Save();
        }

        /// <summary>
        /// Xóa toàn bộ bản ghi với nodeId truyền vào
        /// </summary>
        /// <param name="nodeId"></param>
        public void DeleteByNodeId(int nodeId)
        {
            context.NodeUsers.Where(o => o.NodeId == nodeId).ToList().ForEach(t =>
                {
                    context.NodeUsers.Attach(t);
                    context.NodeUsers.Remove(t);
                });
            Save();
        }

        public void Save()
        {
            context.SaveChanges();
        }

        /// <summary>
        /// Xóa một người dùng
        /// </summary>
        /// <param name="nodeId"></param>
        /// <param name="userId"></param>
        public void Delete(int nodeId, Guid userId)
        {
            context.NodeUsers.Where(o => o.NodeId == nodeId && o.UserId == userId).ToList().ForEach(t =>
            {
                context.NodeUsers.Attach(t);
                context.NodeUsers.Remove(t);
            });
            Save();
        }

        /// <summary>
        /// Điều chỉnh người nào đó trong nút về thành xử lý chính hay bỏ xử lý chính
        /// </summary>
        /// <param name="nodeId"></param>
        /// <param name="userId"></param>
        /// <param name="mainExecutor"></param>
        public void UpdateExecutor(int nodeId, Guid userId, bool mainExecutor)
        {
            var item = context.NodeUsers.FirstOrDefault(o => o.NodeId == nodeId && o.UserId == userId);
            if (null != item)
            {
                item.MainExecutor = mainExecutor;
                context.Entry(item).State = EntityState.Modified;
                Save();
            }
        }
        /// <summary>
        /// Bỏ tất cả người dùng trong nút không còn là xử lý chính
        /// </summary>
        /// <param name="nodeId"></param>
        public void RemoveAllMainExecutor(int nodeId)
        {
            context.NodeUsers.Where(o => o.NodeId == nodeId).ToList().ForEach(t =>
                {
                    t.MainExecutor = false;
                    context.Entry(t).State = EntityState.Modified;
                });
            Save();
        }
    }
}
